SparkN0de-git - /page/commit.mu

Micron Document

--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------

| SparkN0de-git | SparkN0de |

Node / ReticulumProjects / LXMF.git / commits / c0a8f3b

Commit c0a8f3be498514611ccb7e44925bf78afd5d71ac

󰉖 Browse tree at this commit

Parents : 7b4780c

Author : Mark Qvist <mark@unsigned.io>

Date : 2025-01-30T15:04:21+01:00

Cleanup

Changes

2 files changed, 9 insertions(+), 6 deletions(-)

M LXMF/Handlers.py +6 -4

M LXMF/LXMRouter.py +3 -2

Diff

diff --git a/LXMF/Handlers.py b/LXMF/Handlers.py

index 26a5df6..9876f4c 100644

--- a/LXMF/Handlers.py

+++ b/LXMF/Handlers.py

@@ -47,10 +47,12 @@ class LXMFPropagationAnnounceHandler:

propagation_transfer_limit = None

wanted_inbound_peers = None

if len(data) >= 4:

- try:

- wanted_inbound_peers = int(data[3])

- except:

- wanted_inbound_peers = None

+ # TODO: Rethink, probably not necessary anymore

+ # try:

+ # wanted_inbound_peers = int(data[3])

+ # except:

+ # wanted_inbound_peers = None

if len(data) >= 3:

try:

propagation_transfer_limit = float(data[2])

diff --git a/LXMF/LXMRouter.py b/LXMF/LXMRouter.py

index a364a12..070dc71 100644

--- a/LXMF/LXMRouter.py

+++ b/LXMF/LXMRouter.py

@@ -286,7 +286,7 @@ class LXMRouter:

node_state, # Boolean flag signalling propagation node state

int(time.time()), # Current node timebase

self.propagation_per_transfer_limit, # Per-transfer limit for message propagation in kilobytes

- self.get_wanted_inbound_peers(), # How many more inbound peers this node wants

+ None, # How many more inbound peers this node wants

]

data = msgpack.packb(announce_data)

@@ -895,7 +895,8 @@ class LXMRouter:

threading.Thread(target=self.save_outbound_stamp_costs, daemon=True).start()

def get_wanted_inbound_peers(self):

- # TODO: Implement

+ # TODO: Implement/rethink.

+ # Probably not necessary anymore.

return None

def get_announce_app_data(self, destination_hash):

──────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────